package io.gitee.hfl.rocketmq.props;

/**
 * @author hefulin
 * @date 2022/9/7 10:22
 */
public class RocketConsumerProperties {

    /**
     * 消费者数
     */
    private Integer nums = 1;

    /**
     * 单个消费者线程数
     */
    private Integer threadsNums = 15;

    /**
     * 最大消息缓存数量
     */
    private Integer maxCacheMessageCount = 1024;

    /**
     * 最大消息缓存空间
     */
    private Integer maxCacheMessageSizeInBytes = 64 * 1024 * 1024;

    public Integer getNums() {
        return nums;
    }

    public void setNums(Integer nums) {
        this.nums = nums;
    }

    public Integer getThreadsNums() {
        return threadsNums;
    }

    public void setThreadsNums(Integer threadsNums) {
        this.threadsNums = threadsNums;
    }

    public Integer getMaxCacheMessageCount() {
        return maxCacheMessageCount;
    }

    public void setMaxCacheMessageCount(Integer maxCacheMessageCount) {
        this.maxCacheMessageCount = maxCacheMessageCount;
    }

    public Integer getMaxCacheMessageSizeInBytes() {
        return maxCacheMessageSizeInBytes;
    }

    public void setMaxCacheMessageSizeInBytes(Integer maxCacheMessageSizeInBytes) {
        this.maxCacheMessageSizeInBytes = maxCacheMessageSizeInBytes;
    }
}
